
# 获取MQ连接
from pingtai.mqdemo.mqutils import get_connection

connection = get_connection()

# 在连接上创建一个频道CHANNEL
channel = connection.channel()

# 声明队列QUEUE
channel.queue_declare(queue='simple_queue')


# 定义一个回调函数，用来接收生产者发送的消息
def callback(ch, method, properties, body):
    print("[消费者] Received %r" % body)


# 开启一个死循环接受MQ消息。
channel.basic_consume(callback,  # 调用回调函数，从队列里取消息
                      queue='simple_queue',  # 指定取消息的队列名
                      no_ack=True,  # 取完一条消息后，不给生产者发送确认消息，默认是False的
                      )

print('[消费者] Waiting for messages. To exit press CTRL+C')
# 开始循环取消息
channel.start_consuming()
